package JDBCTest;


import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;


public class TestInsert {
    public static void main(String[] args) throws SQLException {
        // 创建数据源对象
        DataSource dataSource = new MysqlDataSource();



        /**
         *  以下这三种方法是子类特有, 接口并没有
         *  需要向下转型
         */

        // 找到服务器在哪
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java112?characterEncoding=utf8&useSSL=false");
        // 确定用户权限
        ((MysqlDataSource)dataSource).setUser("root");
        // 确定密码
        ((MysqlDataSource)dataSource).setPassword("q20031229");


        /**
         * 准备工作做完之后，开始对服务器进行网络连接
         *
         */
        Connection connection = dataSource.getConnection();

        // 输入增加数据
        Scanner scanner = new Scanner(System.in);
         String name =  scanner.nextLine();
         int  id  = scanner.nextInt();

        // 创建 SQL语句

        String sql = "insert into test values (" +  id +  " , '" +  name + "' )";

        // 进行预编译
        PreparedStatement statement = connection.prepareStatement(sql);


        // 执行SQL语句到服务器上
        int num=  statement.executeUpdate();
        System.out.println(num);

        // 释放资源
        statement.close();
        connection.close();
    }
}
